# -*- coding: utf-8 -*-
"""
Author:LeoDuan
Date: 2023/3/23 22:06
"""
from kafka import KafkaConsumer

# 消费者要一直启动着
consumer = KafkaConsumer("text1", bootstrap_servers="192.168.136.129:9092")

for msg in consumer:
    print(msg.value.decode())
